d2948b2388ed091139810805a188cd105317b571,jrpc-transport-netty4/src/main/java/com/dinstone/jrpc/transport/netty4/TransportProtocolDecoder.java,TransportProtocolDecoder,readFrame,#ByteBuf#,71
Before Change
+ ')');
}
if (remaining - 4 >= objectSize) {
objectSize = in.readInt();
// RPC object size
byte[] rpcBytes = new byte[objectSize];
in.readBytes(rpcBytes);
After Change
private byte[] readFrame(ByteBuf in) {
if (in.readableBytes() > 4) {
in.markReaderIndex();
int len = in.readInt();
if (len > maxObjectSize) {
throw new IllegalStateException("The encoded object is too big: " + len + " (> " + maxObjectSize + ")");
} else if (len < 1) {